#pragma once

#include "i_worker_agent.h"

class worker_agent : public i_worker_agent
{

	virtual BOOL processing_from_manager_message();

	virtual BOOL processing_data();

public:
	worker_agent(const SOCKET& sock,
		Concurrency::unbounded_buffer<messages_structures::tag_worker_manager_message>& for_manager_messages,
		Concurrency::unbounded_buffer<messages_structures::tag_manager_worker_message>* from_manager_messages);

	virtual ~worker_agent(void);

	void cancel();

};

